package com.jugheadzhou.influxdb2test.manager;

import com.influxdb.client.InfluxDBClient;
import lombok.extern.slf4j.Slf4j;

import java.util.Map;

/**
 * @author jugheadzhou
 */
@Slf4j
public class IcuCollectBucketApiManager extends AbstractBucketApiManager {

    public IcuCollectBucketApiManager(InfluxDBClient influx2Client, String org, String bucket, String measurement) {
        this.setInflux2Client(influx2Client);
        this.setOrg(org);
        this.setBucket(bucket);
        this.setMeasurement(measurement);
    }

    /**
     * 写数据
     *
     * @param tagsToAdd
     * @param fieldsToAdd
     */
    @Override
    public void writePoint(Map<String, String> tagsToAdd, Map<String, Object> fieldsToAdd) {
        log.info("icu数据写入influxdb2");
        super.writePoint(tagsToAdd, fieldsToAdd);
    }

}
